package org.example;

public class MyConsumer implements Runnable {
    /*
     * 消费数据到Mysql
     * */
    public static void main(String[] args) {
        Consumer consumer = new Consumer("temp");
        consumer.mysql_consume();
    }

    @Override
    public void run() {
        Consumer consumer = new Consumer("temp");
        consumer.mysql_consume();
    }
}
